package com.celeritymq.consumer;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueReceiver;

import com.celeritymq.destination.CelerityQueue;

public class CelerityQueueReceiver extends CelerityMessageConsumer implements QueueReceiver {
	CelerityQueue queue;

	public CelerityQueueReceiver(CelerityQueue queue, String messageSelector) {
		super(messageSelector);
		this.queue = queue;
	}

	@Override
	public Queue getQueue() throws JMSException {
		return queue;
	}

}
